package com.xian.scala.batch

import org.apache.flink.api.scala.ExecutionEnvironment
import org.apache.flink.api.scala._

/**
 * scala版 flink 批处理
 */
object ScalaFlinkBatchTest {
  def main(args: Array[String]): Unit = {
    //获取批处理环境
    val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment








  }
}
